import UNodeMQ, { Exchange, Queue, SingleUNodeMQ } from "../../index";

export default class ProcessPlugin {
  install(singleUnmq: SingleUNodeMQ<any>) {
    //
    singleUnmq.on(this.consume);
  }
  private consume(fun: () => void) {
    fun();
  }
}
